package com.shujia.dim

import com.shujia.util.SparkTool
import org.apache.spark.sql.SparkSession

object DImScenicBoundary extends SparkTool{
  /**
    * 在子类中实现run方法，实现自定义的代码累哦及
    *
    * 在子类run方法的前面加上下面两行代码
    * import spark.implicits._
    * import org.apache.spark.sql.functions._
    *
    * @param spark spark的环境
    */
  override def run(spark: SparkSession): Unit = {
    spark.sql(
      """
        |insert overwrite table dim.dim_scenic_boundary
        |select * from ods.ods_scenic_boundary
        |
      """.stripMargin)
  }
}
